9165667aa3975900ed1f79fd6c612cfd2e05a01f,broker/src/main/java/org/apache/rocketmq/broker/client/net/Broker2Client.java,Broker2Client,resetOffset,#String#String#number#boolean#boolean#,127
Before Change
try {
this.brokerController.getRemotingServer().invokeOneway(entry.getKey(), request, 5000);
log.info("[reset-offset] reset offset success. topic={}, group={}, clientId={}",
new Object[]{topic, group, entry.getValue().getClientId()});
} catch (Exception e) {
log.error("[reset-offset] reset offset exception. topic={}, group={}",
new Object[]{topic, group}, e);
After Change
try {
this.brokerController.getRemotingServer().invokeOneway(entry.getKey(), request, 5000);
log.info("[reset-offset] reset offset success. topic={}, group={}, clientId={}",
topic, group, entry.getValue().getClientId());
} catch (Exception e) {
log.error("[reset-offset] reset offset exception. topic={}, group={}",
new Object[]{topic, group}, e);